--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
meshchatx/src/backend/lxmf_utils.py c0e154c8862d2e0ae98fb3f7ff05cc0cc1a5fd28 (c0e154c8) Text, 12.59 KB
Tff7b72import T7ee787base64
Tff7b72import T7ee787json
Tff7b72import T7ee787LXMF
Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787telemetry_utils Tff7b72import Te6edf3Telemeter
Tff7b72def Td2a8ffconvert_lxmf_message_to_dictTb4b4b4(
Te6edf3lxmf_messageTb4b4b4: Te6edf3LXMFTff7b72.Td2a8ffLXMessageTb4b4b4,
Te6edf3include_attachmentsTb4b4b4: Tffa657bool Tff7b72= Tff7b72TrueTb4b4b4,
Te6edf3reticulumTff7b72=Tff7b72NoneTb4b4b4,
Tb4b4b4)Tb4b4b4:
T8b949e# handle fields
Te6edf3fields Tff7b72= Tb4b4b4{Tb4b4b4}
Te6edf3message_fields Tff7b72= Te6edf3lxmf_messageTff7b72.Td2a8ffget_fieldsTb4b4b4(Tb4b4b4)
Tff7b72for Te6edf3field_type Tff7b72in Te6edf3message_fieldsTb4b4b4:
Te6edf3value Tff7b72= Te6edf3message_fieldsTb4b4b4[Te6edf3field_typeTb4b4b4]
T8b949e# handle file attachments field
Tff7b72if Te6edf3field_type Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffFIELD_FILE_ATTACHMENTSTb4b4b4:
T8b949e# process file attachments
Te6edf3file_attachments Tff7b72= Tb4b4b4[Tb4b4b4]
Tff7b72for Te6edf3file_attachment Tff7b72in Te6edf3valueTb4b4b4:
Te6edf3file_name Tff7b72= Te6edf3file_attachmentTb4b4b4[T79c0ff0Tb4b4b4]
Te6edf3file_data Tff7b72= Te6edf3file_attachmentTb4b4b4[T79c0ff1Tb4b4b4]
Te6edf3file_bytes Tff7b72= Tff7b72None
Tff7b72if Te6edf3include_attachmentsTb4b4b4:
Te6edf3file_bytes Tff7b72= Te6edf3base64Tff7b72.Td2a8ffb64encodeTb4b4b4(Te6edf3file_dataTb4b4b4)Tff7b72.Td2a8ffdecodeTb4b4b4(
Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3file_attachmentsTff7b72.Td2a8ffappendTb4b4b4(
Tb4b4b4{
Ta5d6ff"Ta5d6fffile_nameTa5d6ff"Tb4b4b4: Te6edf3file_nameTb4b4b4,
Ta5d6ff"Ta5d6fffile_sizeTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Te6edf3file_dataTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6fffile_bytesTa5d6ff"Tb4b4b4: Te6edf3file_bytesTb4b4b4,
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
T8b949e# add to fields
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff"Tb4b4b4] Tff7b72= Te6edf3file_attachments
T8b949e# handle image field
Tff7b72if Te6edf3field_type Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffFIELD_IMAGETb4b4b4:
Te6edf3image_type Tff7b72= Te6edf3valueTb4b4b4[T79c0ff0Tb4b4b4]
Te6edf3image_data Tff7b72= Te6edf3valueTb4b4b4[T79c0ff1Tb4b4b4]
Te6edf3image_bytes Tff7b72= Tff7b72None
Tff7b72if Te6edf3include_attachmentsTb4b4b4:
Te6edf3image_bytes Tff7b72= Te6edf3base64Tff7b72.Td2a8ffb64encodeTb4b4b4(Te6edf3image_dataTb4b4b4)Tff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffimageTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffimage_typeTa5d6ff"Tb4b4b4: Te6edf3image_typeTb4b4b4,
Ta5d6ff"Ta5d6ffimage_sizeTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Te6edf3image_dataTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffimage_bytesTa5d6ff"Tb4b4b4: Te6edf3image_bytesTb4b4b4,
Tb4b4b4}
T8b949e# handle audio field
Tff7b72if Te6edf3field_type Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffFIELD_AUDIOTb4b4b4:
Te6edf3audio_mode Tff7b72= Te6edf3valueTb4b4b4[T79c0ff0Tb4b4b4]
Te6edf3audio_data Tff7b72= Te6edf3valueTb4b4b4[T79c0ff1Tb4b4b4]
Te6edf3audio_bytes Tff7b72= Tff7b72None
Tff7b72if Te6edf3include_attachmentsTb4b4b4:
Te6edf3audio_bytes Tff7b72= Te6edf3base64Tff7b72.Td2a8ffb64encodeTb4b4b4(Te6edf3audio_dataTb4b4b4)Tff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffaudioTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffaudio_modeTa5d6ff"Tb4b4b4: Te6edf3audio_modeTb4b4b4,
Ta5d6ff"Ta5d6ffaudio_sizeTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Te6edf3audio_dataTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffaudio_bytesTa5d6ff"Tb4b4b4: Te6edf3audio_bytesTb4b4b4,
Tb4b4b4}
T8b949e# handle telemetry field
Tff7b72if Te6edf3field_type Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffFIELD_TELEMETRYTb4b4b4:
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fftelemetryTa5d6ff"Tb4b4b4] Tff7b72= Te6edf3TelemeterTff7b72.Td2a8fffrom_packedTb4b4b4(Te6edf3valueTb4b4b4)
T8b949e# handle commands field
Tff7b72if Te6edf3field_type Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffFIELD_COMMANDS Tff7b72or Te6edf3field_type Tff7b72== T79c0ff0x01Tb4b4b4:
Te6edf3processed_commands Tff7b72= Tb4b4b4[Tb4b4b4]
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3valueTb4b4b4, Tffa657listTb4b4b4)Tb4b4b4:
Tff7b72for Te6edf3cmd Tff7b72in Te6edf3valueTb4b4b4:
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3cmdTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:
Te6edf3new_cmd Tff7b72= Tb4b4b4{Tb4b4b4}
Tff7b72for Te6edf3kTb4b4b4, Te6edf3v Tff7b72in Te6edf3cmdTff7b72.Td2a8ffitemsTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3kTb4b4b4, Tffa657intTb4b4b4)Tb4b4b4:
Te6edf3new_cmdTb4b4b4[Ta5d6fffTa5d6ff"Ta5d6ff0xTffd700{Te6edf3kTffd700:Ta5d6ff02xTffd700}Ta5d6ff"Tb4b4b4] Tff7b72= Te6edf3v
Tff7b72elseTb4b4b4:
Te6edf3new_cmdTb4b4b4[Tffa657strTb4b4b4(Te6edf3kTb4b4b4)Tb4b4b4] Tff7b72= Te6edf3v
Te6edf3processed_commandsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3new_cmdTb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3processed_commandsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3cmdTb4b4b4)
Tff7b72elif Tffa657isinstanceTb4b4b4(Te6edf3valueTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:
Te6edf3new_cmd Tff7b72= Tb4b4b4{Tb4b4b4}
Tff7b72for Te6edf3kTb4b4b4, Te6edf3v Tff7b72in Te6edf3valueTff7b72.Td2a8ffitemsTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3kTb4b4b4, Tffa657intTb4b4b4)Tb4b4b4:
Te6edf3new_cmdTb4b4b4[Ta5d6fffTa5d6ff"Ta5d6ff0xTffd700{Te6edf3kTffd700:Ta5d6ff02xTffd700}Ta5d6ff"Tb4b4b4] Tff7b72= Te6edf3v
Tff7b72elseTb4b4b4:
Te6edf3new_cmdTb4b4b4[Tffa657strTb4b4b4(Te6edf3kTb4b4b4)Tb4b4b4] Tff7b72= Te6edf3v
Te6edf3processed_commandsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3new_cmdTb4b4b4)
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffcommandsTa5d6ff"Tb4b4b4] Tff7b72= Te6edf3processed_commands
T8b949e# handle reply_to field
Tff7b72if Te6edf3field_type Tff7b72== T79c0ff0x30Tb4b4b4:
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffreply_toTa5d6ff"Tb4b4b4] Tff7b72= Te6edf3valueTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4) Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3valueTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72else Te6edf3value
Tff7b72if Te6edf3field_type Tff7b72== T79c0ff0x31Tb4b4b4:
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffreply_quoted_contentTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4(
Te6edf3valueTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4, Te6edf3errorsTff7b72=Ta5d6ff"Ta5d6ffreplaceTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3valueTb4b4b4, Tffa657bytesTb4b4b4)
Tff7b72else Te6edf3value
Tb4b4b4)
T8b949e# convert 0.0-1.0 progress to 0.00-100 percentage
Te6edf3progress_percentage Tff7b72= Tffa657roundTb4b4b4(Te6edf3lxmf_messageTff7b72.Td2a8ffprogress Tff7b72* T79c0ff100Tb4b4b4, T79c0ff2Tb4b4b4)
T8b949e# get rssi
Te6edf3rssi Tff7b72= Te6edf3lxmf_messageTff7b72.Td2a8ffrssi
Tff7b72if Te6edf3rssi Tff7b72is Tff7b72None Tff7b72and Te6edf3reticulumTb4b4b4:
Te6edf3rssi Tff7b72= Te6edf3reticulumTff7b72.Td2a8ffget_packet_rssiTb4b4b4(Te6edf3lxmf_messageTff7b72.Td2a8ffhashTb4b4b4)
T8b949e# get snr
Te6edf3snr Tff7b72= Te6edf3lxmf_messageTff7b72.Td2a8ffsnr
Tff7b72if Te6edf3snr Tff7b72is Tff7b72None Tff7b72and Te6edf3reticulumTb4b4b4:
Te6edf3snr Tff7b72= Te6edf3reticulumTff7b72.Td2a8ffget_packet_snrTb4b4b4(Te6edf3lxmf_messageTff7b72.Td2a8ffhashTb4b4b4)
T8b949e# get quality
Te6edf3quality Tff7b72= Te6edf3lxmf_messageTff7b72.Td2a8ffq
Tff7b72if Te6edf3quality Tff7b72is Tff7b72None Tff7b72and Te6edf3reticulumTb4b4b4:
Te6edf3quality Tff7b72= Te6edf3reticulumTff7b72.Td2a8ffget_packet_qTb4b4b4(Te6edf3lxmf_messageTff7b72.Td2a8ffhashTb4b4b4)
T8b949e# get reply_to_hash from fields if present
Te6edf3reply_to_hash Tff7b72= Tff7b72None
Tff7b72if T79c0ff0x30 Tff7b72in Te6edf3message_fieldsTb4b4b4:
Te6edf3val Tff7b72= Te6edf3message_fieldsTb4b4b4[T79c0ff0x30Tb4b4b4]
Te6edf3reply_to_hash Tff7b72= Te6edf3valTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4) Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3valTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72else Te6edf3val
Te6edf3content Tff7b72= Tb4b4b4(
Te6edf3lxmf_messageTff7b72.Td2a8ffcontentTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4, Te6edf3errorsTff7b72=Ta5d6ff"Ta5d6ffreplaceTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3lxmf_messageTff7b72.Td2a8ffcontent
Tff7b72else Ta5d6ff"Ta5d6ff"
Tb4b4b4)
T8b949e# auto-detect reply from content if not present
Tff7b72if Tff7b72not Te6edf3reply_to_hash Tff7b72and Te6edf3content Tff7b72and Tffa657isinstanceTb4b4b4(Te6edf3contentTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:
Tff7b72import T7ee787re
Te6edf3match Tff7b72= Te6edf3reTff7b72.Td2a8ffsearchTb4b4b4(Ta5d6ffrTa5d6ff"Ta5d6ff^> ([a-fA-F0-9]Tffd700{32}Ta5d6ff)Ta5d6ff\Ta5d6ffs*Ta5d6ff\Ta5d6ffn?Ta5d6ff"Tb4b4b4, Te6edf3contentTb4b4b4)
Tff7b72if Te6edf3matchTb4b4b4:
Te6edf3reply_to_hash Tff7b72= Te6edf3matchTff7b72.Td2a8ffgroupTb4b4b4(T79c0ff1Tb4b4b4)
Tff7b72return Tb4b4b4{
Ta5d6ff"Ta5d6ffhashTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8ffhashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffsource_hashTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8ffsource_hashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffdestination_hashTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8ffdestination_hashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffis_incomingTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8ffincomingTb4b4b4,
Ta5d6ff"Ta5d6ffstateTa5d6ff"Tb4b4b4: Te6edf3convert_lxmf_state_to_stringTb4b4b4(Te6edf3lxmf_messageTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffprogressTa5d6ff"Tb4b4b4: Te6edf3progress_percentageTb4b4b4,
Ta5d6ff"Ta5d6ffmethodTa5d6ff"Tb4b4b4: Te6edf3convert_lxmf_method_to_stringTb4b4b4(Te6edf3lxmf_messageTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffdelivery_attemptsTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8ffdelivery_attemptsTb4b4b4,
Ta5d6ff"Ta5d6ffnext_delivery_attempt_atTa5d6ff"Tb4b4b4: Tffa657getattrTb4b4b4(
Te6edf3lxmf_messageTb4b4b4,
Ta5d6ff"Ta5d6ffnext_delivery_attemptTa5d6ff"Tb4b4b4,
Tff7b72NoneTb4b4b4,
Tb4b4b4)Tb4b4b4, T8b949e# attribute may not exist yet
Ta5d6ff"Ta5d6fftitleTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8fftitleTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4, Te6edf3errorsTff7b72=Ta5d6ff"Ta5d6ffreplaceTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3lxmf_messageTff7b72.Td2a8fftitle
Tff7b72else Ta5d6ff"Ta5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ffcontentTa5d6ff"Tb4b4b4: Te6edf3contentTb4b4b4,
Ta5d6ff"Ta5d6fffieldsTa5d6ff"Tb4b4b4: Te6edf3fieldsTb4b4b4,
Ta5d6ff"Ta5d6fftimestampTa5d6ff"Tb4b4b4: Te6edf3lxmf_messageTff7b72.Td2a8fftimestampTb4b4b4,
Ta5d6ff"Ta5d6ffrssiTa5d6ff"Tb4b4b4: Te6edf3rssiTb4b4b4,
Ta5d6ff"Ta5d6ffsnrTa5d6ff"Tb4b4b4: Te6edf3snrTb4b4b4,
Ta5d6ff"Ta5d6ffqualityTa5d6ff"Tb4b4b4: Te6edf3qualityTb4b4b4,
Ta5d6ff"Ta5d6ffreply_to_hashTa5d6ff"Tb4b4b4: Te6edf3reply_to_hashTb4b4b4,
Tb4b4b4}
Tff7b72def Td2a8ffconvert_lxmf_state_to_stringTb4b4b4(Te6edf3lxmf_messageTb4b4b4: Te6edf3LXMFTff7b72.Td2a8ffLXMessageTb4b4b4)Tb4b4b4:
T8b949e# convert state to string
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffunknownTa5d6ff"
Tff7b72if Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffGENERATINGTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffgeneratingTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffOUTBOUNDTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffoutboundTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffSENDINGTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffsendingTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffSENTTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffsentTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffDELIVEREDTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffdeliveredTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffREJECTEDTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffrejectedTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffCANCELLEDTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6ffcancelledTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffstate Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffFAILEDTb4b4b4:
Te6edf3lxmf_message_state Tff7b72= Ta5d6ff"Ta5d6fffailedTa5d6ff"
Tff7b72return Te6edf3lxmf_message_state
Tff7b72def Td2a8ffconvert_lxmf_method_to_stringTb4b4b4(Te6edf3lxmf_messageTb4b4b4: Te6edf3LXMFTff7b72.Td2a8ffLXMessageTb4b4b4)Tb4b4b4:
T8b949e# convert method to string
Te6edf3lxmf_message_method Tff7b72= Ta5d6ff"Ta5d6ffunknownTa5d6ff"
Tff7b72if Te6edf3lxmf_messageTff7b72.Td2a8ffmethod Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffOPPORTUNISTICTb4b4b4:
Te6edf3lxmf_message_method Tff7b72= Ta5d6ff"Ta5d6ffopportunisticTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffmethod Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffDIRECTTb4b4b4:
Te6edf3lxmf_message_method Tff7b72= Ta5d6ff"Ta5d6ffdirectTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffmethod Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffPROPAGATEDTb4b4b4:
Te6edf3lxmf_message_method Tff7b72= Ta5d6ff"Ta5d6ffpropagatedTa5d6ff"
Tff7b72elif Te6edf3lxmf_messageTff7b72.Td2a8ffmethod Tff7b72== Te6edf3LXMFTff7b72.Td2a8ffLXMessageTff7b72.Td2a8ffPAPERTb4b4b4:
Te6edf3lxmf_message_method Tff7b72= Ta5d6ff"Ta5d6ffpaperTa5d6ff"
Tff7b72return Te6edf3lxmf_message_method
Tff7b72def Td2a8ffconvert_db_lxmf_message_to_dictTb4b4b4(
Te6edf3db_lxmf_messageTb4b4b4,
Te6edf3include_attachmentsTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4,
Tb4b4b4)Tb4b4b4:
Tff7b72tryTb4b4b4:
Te6edf3fields_str Tff7b72= Te6edf3db_lxmf_messageTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fffieldsTa5d6ff"Tb4b4b4, Ta5d6ff"Tffd700{}Ta5d6ff"Tb4b4b4)
Te6edf3fields Tff7b72= Te6edf3jsonTff7b72.Td2a8ffloadsTb4b4b4(Te6edf3fields_strTb4b4b4) Tff7b72if Te6edf3fields_str Tff7b72else Tb4b4b4{Tb4b4b4}
Tff7b72except Tb4b4b4(Te6edf3jsonTff7b72.Td2a8ffJSONDecodeErrorTb4b4b4, Tf85149TypeErrorTb4b4b4)Tb4b4b4:
Te6edf3fields Tff7b72= Tb4b4b4{Tb4b4b4}
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3fieldsTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:
Te6edf3fields Tff7b72= Tb4b4b4{Tb4b4b4}
T8b949e# normalize commands if present
Tff7b72if Ta5d6ff"Ta5d6ffcommandsTa5d6ff" Tff7b72in Te6edf3fieldsTb4b4b4:
Te6edf3cmds Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffcommandsTa5d6ff"Tb4b4b4]
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3cmdsTb4b4b4, Tffa657listTb4b4b4)Tb4b4b4:
Te6edf3new_cmds Tff7b72= Tb4b4b4[Tb4b4b4]
Tff7b72for Te6edf3cmd Tff7b72in Te6edf3cmdsTb4b4b4:
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3cmdTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:
Te6edf3new_cmd Tff7b72= Tb4b4b4{Tb4b4b4}
Tff7b72for Te6edf3kTb4b4b4, Te6edf3v Tff7b72in Te6edf3cmdTff7b72.Td2a8ffitemsTb4b4b4(Tb4b4b4)Tb4b4b4:
T8b949e# normalize key to 0xXX format if it's a number string
Tff7b72tryTb4b4b4:
Te6edf3ki Tff7b72= Tff7b72None
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3kTb4b4b4, Tffa657intTb4b4b4)Tb4b4b4:
Te6edf3ki Tff7b72= Te6edf3k
Tff7b72elif Tffa657isinstanceTb4b4b4(Te6edf3kTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:
Tff7b72if Te6edf3kTff7b72.Td2a8ffstartswithTb4b4b4(Ta5d6ff"Ta5d6ff0xTa5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3ki Tff7b72= Tffa657intTb4b4b4(Te6edf3kTb4b4b4, T79c0ff16Tb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3ki Tff7b72= Tffa657intTb4b4b4(Te6edf3kTb4b4b4)
Tff7b72if Te6edf3ki Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Te6edf3new_cmdTb4b4b4[Ta5d6fffTa5d6ff"Ta5d6ff0xTffd700{Te6edf3kiTffd700:Ta5d6ff02xTffd700}Ta5d6ff"Tb4b4b4] Tff7b72= Te6edf3v
Tff7b72elseTb4b4b4:
Te6edf3new_cmdTb4b4b4[Tffa657strTb4b4b4(Te6edf3kTb4b4b4)Tb4b4b4] Tff7b72= Te6edf3v
Tff7b72except Tb4b4b4(Tf85149ValueErrorTb4b4b4, Tf85149TypeErrorTb4b4b4)Tb4b4b4:
Te6edf3new_cmdTb4b4b4[Tffa657strTb4b4b4(Te6edf3kTb4b4b4)Tb4b4b4] Tff7b72= Te6edf3v
Te6edf3new_cmdsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3new_cmdTb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3new_cmdsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3cmdTb4b4b4)
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffcommandsTa5d6ff"Tb4b4b4] Tff7b72= Te6edf3new_cmds
T8b949e# strip attachments if requested
Tff7b72if Tff7b72not Te6edf3include_attachmentsTb4b4b4:
Tff7b72if Ta5d6ff"Ta5d6ffimageTa5d6ff" Tff7b72in Te6edf3fieldsTb4b4b4:
T8b949e# keep type but strip bytes
Te6edf3image_size Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffimageTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffimage_sizeTa5d6ff"Tb4b4b4) Tff7b72or T79c0ff0
Te6edf3b64_bytes Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffimageTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffimage_bytesTa5d6ff"Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3image_size Tff7b72and Te6edf3b64_bytesTb4b4b4:
T8b949e# Optimized size calculation without full decoding
Te6edf3image_size Tff7b72= Tb4b4b4(Tffa657lenTb4b4b4(Te6edf3b64_bytesTb4b4b4) Tff7b72* T79c0ff3Tb4b4b4) Tff7b72/Tff7b72/ T79c0ff4
Tff7b72if Te6edf3b64_bytesTff7b72.Td2a8ffendswithTb4b4b4(Ta5d6ff"Ta5d6ff==Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3image_size Tff7b72-Tff7b72= T79c0ff2
Tff7b72elif Te6edf3b64_bytesTff7b72.Td2a8ffendswithTb4b4b4(Ta5d6ff"Ta5d6ff=Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3image_size Tff7b72-Tff7b72= T79c0ff1
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffimageTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffimage_typeTa5d6ff"Tb4b4b4: Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffimageTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffimage_typeTa5d6ff"Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffimage_sizeTa5d6ff"Tb4b4b4: Te6edf3image_sizeTb4b4b4,
Ta5d6ff"Ta5d6ffimage_bytesTa5d6ff"Tb4b4b4: Tff7b72NoneTb4b4b4,
Tb4b4b4}
Tff7b72if Ta5d6ff"Ta5d6ffaudioTa5d6ff" Tff7b72in Te6edf3fieldsTb4b4b4:
T8b949e# keep mode but strip bytes
Te6edf3audio_size Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffaudioTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffaudio_sizeTa5d6ff"Tb4b4b4) Tff7b72or T79c0ff0
Te6edf3b64_bytes Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffaudioTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffaudio_bytesTa5d6ff"Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3audio_size Tff7b72and Te6edf3b64_bytesTb4b4b4:
Te6edf3audio_size Tff7b72= Tb4b4b4(Tffa657lenTb4b4b4(Te6edf3b64_bytesTb4b4b4) Tff7b72* T79c0ff3Tb4b4b4) Tff7b72/Tff7b72/ T79c0ff4
Tff7b72if Te6edf3b64_bytesTff7b72.Td2a8ffendswithTb4b4b4(Ta5d6ff"Ta5d6ff==Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3audio_size Tff7b72-Tff7b72= T79c0ff2
Tff7b72elif Te6edf3b64_bytesTff7b72.Td2a8ffendswithTb4b4b4(Ta5d6ff"Ta5d6ff=Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3audio_size Tff7b72-Tff7b72= T79c0ff1
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffaudioTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffaudio_modeTa5d6ff"Tb4b4b4: Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6ffaudioTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffaudio_modeTa5d6ff"Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffaudio_sizeTa5d6ff"Tb4b4b4: Te6edf3audio_sizeTb4b4b4,
Ta5d6ff"Ta5d6ffaudio_bytesTa5d6ff"Tb4b4b4: Tff7b72NoneTb4b4b4,
Tb4b4b4}
Tff7b72if Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff" Tff7b72in Te6edf3fieldsTb4b4b4:
T8b949e# keep file names but strip bytes
Tff7b72for Te6edf3i Tff7b72in Tffa657rangeTb4b4b4(Tffa657lenTb4b4b4(Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff"Tb4b4b4]Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3file_size Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3iTb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fffile_sizeTa5d6ff"Tb4b4b4) Tff7b72or T79c0ff0
Te6edf3b64_bytes Tff7b72= Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3iTb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fffile_bytesTa5d6ff"Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3file_size Tff7b72and Te6edf3b64_bytesTb4b4b4:
Te6edf3file_size Tff7b72= Tb4b4b4(Tffa657lenTb4b4b4(Te6edf3b64_bytesTb4b4b4) Tff7b72* T79c0ff3Tb4b4b4) Tff7b72/Tff7b72/ T79c0ff4
Tff7b72if Te6edf3b64_bytesTff7b72.Td2a8ffendswithTb4b4b4(Ta5d6ff"Ta5d6ff==Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3file_size Tff7b72-Tff7b72= T79c0ff2
Tff7b72elif Te6edf3b64_bytesTff7b72.Td2a8ffendswithTb4b4b4(Ta5d6ff"Ta5d6ff=Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3file_size Tff7b72-Tff7b72= T79c0ff1
Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3iTb4b4b4] Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6fffile_nameTa5d6ff"Tb4b4b4: Te6edf3fieldsTb4b4b4[Ta5d6ff"Ta5d6fffile_attachmentsTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3iTb4b4b4]Tff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fffile_nameTa5d6ff"Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6fffile_sizeTa5d6ff"Tb4b4b4: Te6edf3file_sizeTb4b4b4,
Ta5d6ff"Ta5d6fffile_bytesTa5d6ff"Tb4b4b4: Tff7b72NoneTb4b4b4,
Tb4b4b4}
T8b949e# ensure created_at and updated_at have Z suffix for UTC if they don't have a timezone
Te6edf3created_at Tff7b72= Tffa657strTb4b4b4(Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffcreated_atTa5d6ff"Tb4b4b4]Tb4b4b4)
Tff7b72if Te6edf3created_at Tff7b72and Ta5d6ff"Ta5d6ff+Ta5d6ff" Tff7b72not Tff7b72in Te6edf3created_at Tff7b72and Ta5d6ff"Ta5d6ffZTa5d6ff" Tff7b72not Tff7b72in Te6edf3created_atTb4b4b4:
Te6edf3created_at Tff7b72+Tff7b72= Ta5d6ff"Ta5d6ffZTa5d6ff"
Te6edf3updated_at Tff7b72= Tffa657strTb4b4b4(Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4]Tb4b4b4)
Tff7b72if Te6edf3updated_at Tff7b72and Ta5d6ff"Ta5d6ff+Ta5d6ff" Tff7b72not Tff7b72in Te6edf3updated_at Tff7b72and Ta5d6ff"Ta5d6ffZTa5d6ff" Tff7b72not Tff7b72in Te6edf3updated_atTb4b4b4:
Te6edf3updated_at Tff7b72+Tff7b72= Ta5d6ff"Ta5d6ffZTa5d6ff"
Tff7b72return Tb4b4b4{
Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffhashTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffhashTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffsource_hashTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffsource_hashTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffdestination_hashTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffdestination_hashTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffis_incomingTa5d6ff"Tb4b4b4: Tffa657boolTb4b4b4(Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffis_incomingTa5d6ff"Tb4b4b4]Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffstateTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffstateTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffprogressTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffprogressTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffmethodTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffmethodTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffdelivery_attemptsTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffdelivery_attemptsTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffnext_delivery_attempt_atTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffnext_delivery_attempt_atTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6fftitleTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6fftitleTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffcontentTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffcontentTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6fffieldsTa5d6ff"Tb4b4b4: Te6edf3fieldsTb4b4b4,
Ta5d6ff"Ta5d6fftimestampTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6fftimestampTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffrssiTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffrssiTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffsnrTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffsnrTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffqualityTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffqualityTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6ffis_spamTa5d6ff"Tb4b4b4: Tffa657boolTb4b4b4(Te6edf3db_lxmf_messageTb4b4b4[Ta5d6ff"Ta5d6ffis_spamTa5d6ff"Tb4b4b4]Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffreply_to_hashTa5d6ff"Tb4b4b4: Te6edf3db_lxmf_messageTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffreply_to_hashTa5d6ff"Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffcreated_atTa5d6ff"Tb4b4b4: Te6edf3created_atTb4b4b4,
Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4: Te6edf3updated_atTb4b4b4,
Tb4b4b4}
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────